package aliyun

import (
	"context"

	mqhttpsdk "github.com/aliyunmq/mq-http-go-sdk"
	"testkjcld.bhecard.com/gitlab/kit/esim/rocketmq/internal"
)

type AliyunTranProducer struct {
	mqhttpsdk.MQTransProducer
}

func (p *AliyunTranProducer) Start() error {
	return nil
}

func (p *AliyunTranProducer) Shutdown() error {
	return nil
}

func (p *AliyunTranProducer) SendMessageInTransaction(ctx context.Context, mq *internal.Message) (*internal.TransactionSendResult, error) {
	return nil, nil
}
